package com.example.lkfy.consumer;

import com.example.lkfy.model.MyConsumer;
import com.example.lkfy.server.RedisConsumer;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@MyConsumer(topic = "tag")
public class TagConsumer implements RedisConsumer {
    /**
     * 消费当前标签
     * @param message 消息体
     */
    @Override
    public void deal(Object message) {
        log.info("tag标签，接收成功:" + message );
    }
}
